package com.sealer;

import com.sealer.rpc.exporter.RpcExporter;

import java.io.IOException;
import java.util.concurrent.Executors;

/**
 * @author sealer
 * @date 2017/02/07
 */
public class Main {
    public static void main(String[] args) {
        System.out.println("Rpc server is starting.");
        Executors.newSingleThreadExecutor().execute(() -> {
            try {
                RpcExporter.exports("localhost", 8088);
            } catch (IOException e) {
                System.out.println("Rpc server started failed.");
                throw new RuntimeException(e);
            }
        });
        System.out.println("Rpc server started.");
    }
}

/**
 * 编解码方式， 在dubbo中指的是 Protocol, eg. dubbo
 * 这里的选型时： java bio阻塞式通信, 基于TCP Socket通信， 最好改进为netty4
 */